package com.hanson.demo.queue;

import com.hanson.demo.actors.Message;

public interface TbQueueProducer<T extends Message> {

    void init();

    String getDefaultTopic();

    void send(String tpi, T msg, TbQueueCallback callback);

    void stop();
}
